package cn.lingyangwl.framework.rabbitmq.repeatconsume;

/**
 * 用于解决重复消费服务
 * @deprecated
 * @author shenguangyang
 * @since 1.0.0
 */
public interface MqRepeatConsumeService {
    /**
     * 判断是否已经被消费过
     *
     * @param msgId 消息id
     * @return boolean
     */
    boolean isConsumed(String msgId);

    /**
     * 标记已经被消费
     *
     * @param msgId 消费id
     */
    void markConsumed(String msgId);
}
